package cn.mjnxin.iot.gate.worker;

import cn.mjnxin.iot.base.domain.ChannelData;
import cn.mjnxin.iot.base.process.DataProcessWorker;

/**
 * 网关间报文中转
 * 
 * @Description: 终端报文实际发送前置
 * @author mjnxin.cn
 * @date 2023年10月10日
 * @version V1.0.0
 */
public class Gate2GateWorker extends DataProcessWorker<ChannelData> {
	private static Gate2GateWorker worker = null;
	
	//非单例模式：调用一次就初始化一次
	public static void init(int poolSize) throws Exception {
		worker = new Gate2GateWorker(poolSize);
	}

	public static Gate2GateWorker getInstance() {
		return worker;
	}

	private Gate2GateWorker(int poolSize) throws Exception {
		super(poolSize, "Gate2GateWorker");
		this.start();
	}

	@Override
	protected void proccess(ChannelData channelData) throws Exception {
		
	}
}
